package com.kloooong.top.push;

import com.alibaba.fastjson.JSONObject;
import com.dingteam.push.api.channel.MarketOrderChannel;
import com.dingteam.push.api.channel.MarketOrderInput;
import com.dingteam.push.api.channel.OrgSuiteTicketChannel;
import com.dingteam.push.api.channel.OrgSuiteTicketInput;
import com.dingteam.push.api.message.MarketOrderMessage;
import com.dingteam.push.api.message.OrgSuiteTicketMessage;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
@EnableBinding(OrgSuiteTicketChannel.class)
public class BizId02 {


    @StreamListener(target = OrgSuiteTicketInput.INPUT ,condition = "headers['syncAction']=='suite_ticket' and headers['suiteId']=='"+Contain.stuidId666+"'")
    public void suid666(OrgSuiteTicketMessage suiteTicket) {
        System.out.println("666 02 data is coming 。。。");
        System.out.println("data："+ JSONObject.toJSONString(suiteTicket));
    }


    @StreamListener(target = OrgSuiteTicketInput.INPUT ,condition = "headers['syncAction']=='suite_ticket' and headers['suiteId']=='"+Contain.stuidId777+"'")
    public void suid777(OrgSuiteTicketMessage suiteTicket) {
        System.out.println("777 02 data is coming 。。。");
        System.out.println("data："+ JSONObject.toJSONString(suiteTicket));
    }



}
